package com.yifeng.repo.flink.data.transport.config;

import java.io.Serializable;

import lombok.Data;

/**
 * Flink 上下文环境变量配置
 * @author lijing
 * @since 2023-03-14
 *
 */
@Data
public class StreamExecutionConfig implements Serializable {

	private static final long serialVersionUID = 1L;
	
	/**
	 * 全局并行度
	 */
	private Integer parallelism;

	/**
	 * checkpoint的存储地址
	 */
	private String stateBackend;

	/**
	 * checkpoint最小间隔
	 */
	private Long minPauseBetweenCheckpoints;
	
	/**
	 * checkpoint的超时时间
	 */
	private Long checkpointTimeout;
	
	/**
	 *检查点多久保存一次
	 */
	private Long checkpointInterval;
	
	/**
	 * 同一时间允许进行的检查点次数
	 */
	private Integer maxConcurrentCheckpoints;
	
	private Integer tolerableCheckpointFailureNumber;
	
}
